package config

type KafkaConfig struct {
	Link     string `json:"link" mapstructure:"link" yaml:"link"`          //连接地址 可以为IP:PORT可以为域名
	AORMode  int    `json:"aORMode" mapstructure:"aORMode" yaml:"aORMode"` // 0[从消费开始后产生的新消息开始消费] 1[从最早的消息开始消费]
	UserName string `json:"userName" mapstructure:"userName" yaml:"userName"`
	Password string `json:"password" mapstructure:"password" yaml:"password"`
}
